from tasks import add
from tasks import job_info
import time

# 报错解决1：https://app.yinxiang.com/shard/s57/nl/13087044/3872797c-3344-44f3-a8fb-0c866b0c2dae
# 报错解决2：https://app.yinxiang.com/shard/s57/nl/13087044/cb8b0009-7553-41e2-9a46-195c01321199









# 不要直接 add(4, 4)，这里需要用 celery 提供的接口 delay 进行调用
job1 = add.delay(123, 456)

# ready() 方法查看任务是否完成处理
while not job1.ready():
    print("任务还没完成，我等待1秒钟。。。")
    time.sleep(1)

# 打印队列里异步任务执行结束的返回值
print(job1.get())


















# job2 = job_info.delay("test1", "*/5 * * * *")
# print(job2.get())

# list1 = [1, 2, 3, 4, 5, 6, 7, 8, 9]
# list2 = [10, 20, 30, 40, 50, 60, 70, 80, 90]
#
# for n in list1:
#     job3 = add.delay(n, n)
# print(job3.get())
